import mysql.connector
from mysql.connector import Error

try:
    # 连接数据库
    conn = mysql.connector.connect(
        host="localhost",   # 本地数据库
        user="root",        # 用户名
        password="111111", # 密码
        port=3306,          # 端口（默认3306可不写）
        database="gardevoir"  # 数据库名（可选，若省略则连接到默认库）
    )

    if conn.is_connected():
        print("成功连接到MySQL数据库！")
        cursor = conn.cursor()

        cursor.execute("""
            CREATE TABLE IF NOT EXISTS users (
                id INT AUTO_INCREMENT PRIMARY KEY,
                name VARCHAR(255),
                email VARCHAR(255)
            )
        """)

        # 示例：插入数据
        cursor.execute("INSERT INTO users (name, email) VALUES (%s, %s)",
                      ("Alice", "alice@example.com"))
        conn.commit()  # 提交事务

        # 示例：查询数据
        cursor.execute("SELECT * FROM users")
        rows = cursor.fetchall()
        print("查询结果：")
        for row in rows:
            print(row)

except Error as e:
    print(f"数据库连接失败: {e}")

finally:
    # 关闭连接（无论是否报错）
    if 'conn' in locals() and conn.is_connected():
        cursor.close()
        conn.close()
        print("数据库连接已关闭")